2c9848214ad9782e3afe637193c0984d16ff49a1,src/test/java/net/jodah/recurrent/RecurrentFutureTest.java,RecurrentFutureTest,testListenersForSuccessfulCompletion,#,102

Before Change


    when(service.connect()).thenThrow(failures(2, SocketException.class)).thenReturn(false, false, true);

    // When
    registerListeners(Recurrent.get(callable, new RetryPolicy().retryWhen(false), executor));
    waiter.await(1000, 6);

    // Then

After Change


    when(service.connect()).thenThrow(failures(2, SocketException.class)).thenReturn(false, false, true);

    // When
    registerListeners(Recurrent.with(new RetryPolicy().retryWhen(false), executor).get(callable));
    waiter.await(1000, 6);

    // Then